package code.nest.util.kafka;

/**
 * <h3>kafka-ts</h3>
 * <p>使用kafaka发送消息的接口</p>
 *
 * @author : Hyman
 * @date : 2021-06-22 16:03
 **/
public interface KafkaProducerService<T> {
    /**
     * create by: Hyman
     * description: 发送并忘记的发送方式
     * create time: 2021/6/22
     */
    void sendFireAndForgetMsg(String topic, String key, T t);

    /**
     * create by: Hyman
     * description: 同步发送方式
     * create time: 2021/6/22
     */
    void sendFutureMsg(String topic, String key, T t);

    /**
     * create by: Hyman
     * description: 异步发送方式
     * create time: 2021/6/22
     */
    void sendAsynMsg(String topic, String key, T t);
}
